import pymysql
# 打开数据库连接
conn = pymysql.connect(
    user = 'root',
    passwd = '123456',
    db = 'bs',
    host = '127.0.0.1',
    port = 3306,
    charset = 'utf8',
    autocommit = True  # 自动提交确认
)
 
# 使用cursor()方法创建一个游标对象cursor
cursor = conn.cursor()      # 游标对象用于执行查询和获取结果

# 使用execute()方法执行SQL,如果表存在则将其删除
sql_1="""DROP TABLE IF EXISTS DATA"""
cursor.execute(sql_1)
    # 使用预处理语句创建表
sql_2 = """CREATE TABLE DATA (
    `Ccode` VARCHAR(10) DEFAULT NULL COMMENT '分类代码',
    `Cshares` VARCHAR(10) DEFAULT NULL COMMENT '股票类别',
    `code` VARCHAR(10) DEFAULT NULL COMMENT '股票代码',
    `name` VARCHAR(10) DEFAULT NULL COMMENT '股票名称',
    `price` FLOAT DEFAULT NULL COMMENT '当前价格',
    `Iad` FLOAT DEFAULT NULL COMMENT '涨跌额',
    `Uadr` FLOAT DEFAULT NULL COMMENT '涨跌幅',
    `YTD` FLOAT DEFAULT NULL COMMENT '年初至今',
    `Turnover` FLOAT DEFAULT NULL COMMENT '成交量',
    `money` FLOAT DEFAULT NULL COMMENT '成交额',
    `Trate` FLOAT DEFAULT NULL COMMENT '换手率',
    `dividend_yield` FLOAT DEFAULT NULL COMMENT '股息率',
    `market_value` FLOAT DEFAULT NULL COMMENT '市值'
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    """
try:
    cursor.execute(sql_2)
    print("success!")
except:
    # 发生错误时回滚
    conn.rollback()
    print("Error")
    # 关闭数据库连接
conn.close()
